public class HadoopIoStep extends VertexProgramStep implements ReadWriting
GraphTraversalSource.io(String) which uses the
CloneVertexProgram for its implementation. Standard Hadoop OLAP configurations can be passed using the
GraphTraversal.with(String, Object) step modulator as all options aside from those in IO will be
transferred.ReadWriting.Modecomputer, first, ROOT_TRAVERSAL, STEP_IDid, labels, nextEnd, nextStep, previousStep, starts, traversal, traverserStepIdAndLabelsSetByChild| Constructor and Description |
|---|
HadoopIoStep(Traversal.Admin traversal,
String file) |
| Modifier and Type | Method and Description |
|---|---|
HadoopIoStep |
clone()
Cloning is used to duplicate steps for the purpose of traversal optimization and OLTP replication.
|
void |
configure(Object... keyValues)
Accept a configuration to the
Step. |
CloneVertexProgram |
generateProgram(Graph graph,
Memory memory)
Generate the
VertexProgram. |
String |
getFile()
Get the file location to write to.
|
ReadWriting.Mode |
getMode() |
Parameters |
getParameters()
Gets the parameters on the step.
|
int |
hashCode() |
void |
setMode(ReadWriting.Mode mode) |
String |
toString() |
getComputer, isEndStep, previousTraversalVertexProgram, processNextStart, setComputeraddLabel, addStart, addStarts, equals, getId, getLabels, getNextStep, getPreviousStep, getStarts, getTraversal, hasNext, isTraverserStepIdAndLabelsSetByChild, next, prepareTraversalForNextStep, removeLabel, reset, setId, setNextStep, setPreviousStep, setTraversalfinalize, getClass, notify, notifyAll, wait, wait, waitequals, getRequirementsforEachRemaining, removepublic HadoopIoStep(Traversal.Admin traversal, String file)
public void setMode(ReadWriting.Mode mode)
setMode in interface ReadWritingpublic ReadWriting.Mode getMode()
getMode in interface ReadWritingpublic String getFile()
ReadWritinggetFile in interface ReadWritingpublic void configure(Object... keyValues)
ConfiguringStep. Note that this interface extends Parameterizing and so
there is an expectation that the Step implementation will have a Parameters instance that will
house any values passed to this method. Storing these configurations in Parameters is not a requirement
however, IF the configuration is an expected option for the step and can be stored on a member field that can
be accessed on the step by more direct means (i.e. like a getter method).configure in interface Configuringpublic Parameters getParameters()
ParameterizinggetParameters in interface Parameterizingpublic String toString()
toString in class AbstractStep<ComputerResult,ComputerResult>public CloneVertexProgram generateProgram(Graph graph, Memory memory)
VertexComputingVertexProgram.generateProgram in interface VertexComputinggraph - the Graph that the program will be executed over.memory - the Memory from the previous OLAP job if it exists, else its an empty memory structure.public HadoopIoStep clone()
StepStep.reset() is called. Moreover, the previous and next steps should be set to EmptyStep.clone in interface Step<ComputerResult,ComputerResult>clone in class AbstractStep<ComputerResult,ComputerResult>public int hashCode()
hashCode in class AbstractStep<ComputerResult,ComputerResult>Copyright © 2013–2021 Apache Software Foundation. All rights reserved.