public abstract class InputAdapter extends Operator
Operator.sendOutput(int,Tuple)
to provide tuples to the
application.
For in-depth information on implementing an input adapter, please
see "Using the Embedded Adapter API" in the StreamBase
documentation.Operator.ConfigurationAccessor, Operator.IconKind, Operator.LogLevel, Operator.OperatorStates, Operator.OperatorThread, Operator.PropertyTypecheckException, Operator.RuntimeEnvironment, Operator.SharedObject, Operator.SharedObjectManager, Operator.SuspendBehaviorStates
DEFAULT_STATE_CHANGE_TIMEOUT, OP_CONFIG_MGR_NO_CONF
Constructor and Description |
---|
InputAdapter() |
Modifier and Type | Method and Description |
---|---|
void |
processTuple(int inputPort,
Tuple tuple)
This method will be called by the StreamBase server for each Tuple given
to the Operator to process.
|
allowsConcurrency, evaluate, getCaptureStrategy, getContainerName, getDisplayName, getFullyQualifiedName, getIconResource, getInputPortCount, getInputSchema, getLocation, getLocation, getLogger, getName, getOperatorConfigurationAccessor, getOutputPortCount, getOutputSchema, getParameters, getPortCounts, getProposedInputSchemas, getProposedOutputSchemas, getResourceContents, getResourceFile, getReuseTuple, getRuntimeEnvironment, getRuntimeInputSchema, getRuntimeOutputSchema, getSchemaForCapture, getSearchKeywords, getShortDisplayName, getStateChangeTimeout, getTableAccessor, getTupleCaptureTransformer, getTypecheckInputSchema, getTypecheckOutputSchema, hasNotYetStarted, init, isDesignTime, isDroppingTuples, isPassthruOperator, isProcessingTuples, isRunning, isShutdown, isSuspended, postShutdown, registerRunnable, registerRunnable, registerRunnable, registerRunnable, requireInputPortCount, resume, resumed, scheduleRunnable, sendErrorOutput, sendErrorOutput, sendErrorOutput, sendOutput, sendOutput, sendOutputAsync, sendOutputAsync, setCaptureStrategy, setDisplayName, setLogLevel, setLogLevel, setOutputSchema, setParameters, setPortHints, setReuseTuple, setShortDisplayName, setSuspendBehavior, shouldRun, shutdown, size, suspend, suspended, typecheck
public void processTuple(int inputPort, Tuple tuple) throws StreamBaseException
Operator
Operator.setReuseTuple(boolean)
.processTuple
in class Operator
inputPort
- the input port that the tuple is from (ports are zero based)tuple
- the tuple from the given input portStreamBaseException
- Terminates the application.