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–2022 The Apache Software Foundation. All rights reserved.