Package | Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
void |
PigServer.registerStreamingCommand(String commandAlias,
StreamingCommand command)
Defines an alias for the given streaming command.
|
Modifier and Type | Method and Description |
---|---|
StreamingCommand |
POStream.getCommand()
Get the
StreamingCommand for this StreamSpec . |
Constructor and Description |
---|
POStream(OperatorKey k,
ExecutableManager executableManager,
StreamingCommand command,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
StreamingCommand |
PigContext.getCommandForAlias(String alias)
Get the
StreamingCommand for the given alias. |
Modifier and Type | Method and Description |
---|---|
void |
PigContext.registerStreamCmd(String alias,
StreamingCommand command)
Defines an alias for the given streaming command.
|
Modifier and Type | Field and Description |
---|---|
protected StreamingCommand |
ExecutableManager.command |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
StreamingCommand |
LOStream.getStreamingCommand()
Get the StreamingCommand object associated
with this operator
|
Constructor and Description |
---|
LOStream(LogicalPlan plan,
ExecutableManager exeManager,
StreamingCommand cmd,
LogicalSchema schema) |
Copyright © 2007-2017 The Apache Software Foundation