@Deprecated public class EsTap extends Tap<Object,Object,Object>
Constructor and Description |
---|
EsTap(String resource)
Deprecated.
|
EsTap(String resource,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource)
Deprecated.
|
EsTap(String host,
int port,
String resource,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query,
Fields fields,
Properties tapSettings)
Deprecated.
|
EsTap(String resource,
String query)
Deprecated.
|
EsTap(String resource,
String query,
Fields fields)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
createResource(Object conf)
Deprecated.
|
boolean |
deleteResource(Object conf)
Deprecated.
|
void |
flowConfInit(Flow<Object> flow)
Deprecated.
|
String |
getIdentifier()
Deprecated.
|
long |
getModifiedTime(Object conf)
Deprecated.
|
static void |
initCredentials(Properties flowConnectorProperties)
Deprecated.
If Kerberos Security is enabled for Hadoop and Elasticsearch, this function will securely contact Elasticsearch
using Kerberos to authenticate, and retrieve a delegation token for use by worker processes on the cluster.
|
boolean |
isEquivalentTo(FlowElement element)
Deprecated.
|
boolean |
isSink()
Deprecated.
|
boolean |
isSource()
Deprecated.
|
TupleEntryIterator |
openForRead(FlowProcess<Object> flowProcess,
Object input)
Deprecated.
|
TupleEntryCollector |
openForWrite(FlowProcess<Object> flowProcess,
Object output)
Deprecated.
|
boolean |
resourceExists(Object conf)
Deprecated.
|
void |
sinkConfInit(FlowProcess<Object> flowProcess,
Object conf)
Deprecated.
|
void |
sourceConfInit(FlowProcess<Object> flowProcess,
Object conf)
Deprecated.
|
String |
toString()
Deprecated.
|
commitResource, createResource, deleteResource, equals, getConfigDef, getFullIdentifier, getFullIdentifier, getModifiedTime, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isKeep, isReplace, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, taps
public EsTap(String resource)
public EsTap(String host, int port, String resource, String query, Fields fields, Properties tapSettings)
public void flowConfInit(Flow<Object> flow)
flowConfInit
in class Tap<Object,Object,Object>
public boolean isSource()
public String getIdentifier()
getIdentifier
in class Tap<Object,Object,Object>
public void sourceConfInit(FlowProcess<Object> flowProcess, Object conf)
sourceConfInit
in class Tap<Object,Object,Object>
public void sinkConfInit(FlowProcess<Object> flowProcess, Object conf)
sinkConfInit
in class Tap<Object,Object,Object>
public TupleEntryIterator openForRead(FlowProcess<Object> flowProcess, Object input) throws IOException
openForRead
in class Tap<Object,Object,Object>
IOException
public TupleEntryCollector openForWrite(FlowProcess<Object> flowProcess, Object output) throws IOException
openForWrite
in class Tap<Object,Object,Object>
IOException
public boolean createResource(Object conf) throws IOException
createResource
in class Tap<Object,Object,Object>
IOException
public boolean deleteResource(Object conf) throws IOException
deleteResource
in class Tap<Object,Object,Object>
IOException
public boolean resourceExists(Object conf) throws IOException
resourceExists
in class Tap<Object,Object,Object>
IOException
public long getModifiedTime(Object conf) throws IOException
getModifiedTime
in class Tap<Object,Object,Object>
IOException
public boolean isEquivalentTo(FlowElement element)
isEquivalentTo
in interface FlowElement
isEquivalentTo
in class Tap<Object,Object,Object>
public String toString()
public static void initCredentials(Properties flowConnectorProperties)
flowConnectorProperties
- The runtime properties for the Hadoop Flow Connector. Hadoop settings will also be loaded from
the classpath.