public abstract class InputAdapter extends Operator
Input adapters should call
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, getAsyncInputPorts, getCaptureStrategy, getContainerName, getDisplayDescription, getDisplayName, getDynamicVariables, getDynamicVariablesSchema, getFullyQualifiedName, getIconResource, getInputPortCount, getInputSchema, getLocation, getLocation, getLogger, getName, getNamedSchema, 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, isRuntime, isShutdown, isSuspended, postShutdown, registerRunnable, registerRunnable, registerRunnable, registerRunnable, requireInputPortCount, resume, resumed, scheduleRunnable, sendErrorOutput, sendErrorOutput, sendErrorOutput, sendOutput, sendOutput, sendOutputAsync, sendOutputAsync, setCaptureStrategy, setDisplayDescription, setDisplayName, setDynamicVariable, setLogLevel, setLogLevel, setOutputSchema, setParameters, setPortHints, setReuseTuple, setShortDisplayName, setSuspendBehavior, shouldRun, shutdown, size, suspend, suspended, typecheck
public void processTuple(int inputPort, Tuple tuple) throws StreamBaseException
Operator
By default the Tuple passed in is safe for storing and mutating after the
return of processTuple. The details of this Tuple's life cycle can be
controlled via 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.