public class FetchEmitTuple extends Object implements Serializable
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
FetchEmitTuple.ON_PARSE_EXCEPTION  | 
| Modifier and Type | Field and Description | 
|---|---|
static FetchEmitTuple.ON_PARSE_EXCEPTION | 
DEFAULT_ON_PARSE_EXCEPTION  | 
| Constructor and Description | 
|---|
FetchEmitTuple(String id,
              FetchKey fetchKey,
              EmitKey emitKey)  | 
FetchEmitTuple(String id,
              FetchKey fetchKey,
              EmitKey emitKey,
              FetchEmitTuple.ON_PARSE_EXCEPTION onParseException)  | 
FetchEmitTuple(String id,
              FetchKey fetchKey,
              EmitKey emitKey,
              Metadata metadata)  | 
FetchEmitTuple(String id,
              FetchKey fetchKey,
              EmitKey emitKey,
              Metadata metadata,
              HandlerConfig handlerConfig,
              FetchEmitTuple.ON_PARSE_EXCEPTION onParseException)  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
equals(Object o)  | 
EmitKey | 
getEmitKey()  | 
FetchKey | 
getFetchKey()  | 
HandlerConfig | 
getHandlerConfig()  | 
String | 
getId()  | 
Metadata | 
getMetadata()  | 
FetchEmitTuple.ON_PARSE_EXCEPTION | 
getOnParseException()  | 
int | 
hashCode()  | 
void | 
setEmitKey(EmitKey emitKey)  | 
void | 
setHandlerConfig(HandlerConfig handlerConfig)  | 
String | 
toString()  | 
public static final FetchEmitTuple.ON_PARSE_EXCEPTION DEFAULT_ON_PARSE_EXCEPTION
public FetchEmitTuple(String id, FetchKey fetchKey, EmitKey emitKey, FetchEmitTuple.ON_PARSE_EXCEPTION onParseException)
public FetchEmitTuple(String id, FetchKey fetchKey, EmitKey emitKey, Metadata metadata)
public FetchEmitTuple(String id, FetchKey fetchKey, EmitKey emitKey, Metadata metadata, HandlerConfig handlerConfig, FetchEmitTuple.ON_PARSE_EXCEPTION onParseException)
public String getId()
public FetchKey getFetchKey()
public EmitKey getEmitKey()
public Metadata getMetadata()
public FetchEmitTuple.ON_PARSE_EXCEPTION getOnParseException()
public void setEmitKey(EmitKey emitKey)
public void setHandlerConfig(HandlerConfig handlerConfig)
public HandlerConfig getHandlerConfig()
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.