|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use StreamingCommand | |
|---|---|
| org.apache.pig | Public interfaces and classes for Pig. |
| org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | |
| org.apache.pig.impl | |
| org.apache.pig.impl.streaming | |
| org.apache.pig.newplan.logical.relational | |
| Uses of StreamingCommand in org.apache.pig |
|---|
| Methods in org.apache.pig with parameters of type StreamingCommand | |
|---|---|
void |
PigServer.registerStreamingCommand(String commandAlias,
StreamingCommand command)
Defines an alias for the given streaming command. |
| Uses of StreamingCommand in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return StreamingCommand | |
|---|---|
StreamingCommand |
POStream.getCommand()
Get the StreamingCommand for this StreamSpec. |
| Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type StreamingCommand | |
|---|---|
POStream(OperatorKey k,
ExecutableManager executableManager,
StreamingCommand command,
Properties properties)
|
|
| Uses of StreamingCommand in org.apache.pig.impl |
|---|
| Methods in org.apache.pig.impl that return StreamingCommand | |
|---|---|
StreamingCommand |
PigContext.getCommandForAlias(String alias)
Get the StreamingCommand for the given alias. |
| Methods in org.apache.pig.impl with parameters of type StreamingCommand | |
|---|---|
void |
PigContext.registerStreamCmd(String alias,
StreamingCommand command)
Defines an alias for the given streaming command. |
| Uses of StreamingCommand in org.apache.pig.impl.streaming |
|---|
| Fields in org.apache.pig.impl.streaming declared as StreamingCommand | |
|---|---|
protected StreamingCommand |
ExecutableManager.command
|
| Methods in org.apache.pig.impl.streaming with parameters of type StreamingCommand | |
|---|---|
static InputHandler |
HandlerFactory.createInputHandler(StreamingCommand command)
Create an InputHandler for the given input specification
of the StreamingCommand. |
static OutputHandler |
HandlerFactory.createOutputHandler(StreamingCommand command)
Create an OutputHandler for the given output specification
of the StreamingCommand. |
static ProcessBuilder |
StreamingUtil.createProcess(StreamingCommand command)
Create an external process for StreamingCommand command. |
| Uses of StreamingCommand in org.apache.pig.newplan.logical.relational |
|---|
| Methods in org.apache.pig.newplan.logical.relational that return StreamingCommand | |
|---|---|
StreamingCommand |
LOStream.getStreamingCommand()
Get the StreamingCommand object associated with this operator |
| Constructors in org.apache.pig.newplan.logical.relational with parameters of type StreamingCommand | |
|---|---|
LOStream(LogicalPlan plan,
ExecutableManager exeManager,
StreamingCommand cmd,
LogicalSchema schema)
|
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||