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.