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.Mode
computer, first, ROOT_TRAVERSAL, STEP_ID
id, 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, setComputer
addLabel, addStart, addStarts, equals, getId, getLabels, getNextStep, getPreviousStep, getStarts, getTraversal, hasNext, hasStarts, isTraverserStepIdAndLabelsSetByChild, next, prepareTraversalForNextStep, removeLabel, reset, setId, setNextStep, setPreviousStep, setTraversal
finalize, getClass, notify, notifyAll, wait, wait, wait
equals, getRequirements
forEachRemaining, remove
public HadoopIoStep(Traversal.Admin traversal, String file)
public void setMode(ReadWriting.Mode mode)
setMode
in interface ReadWriting
public ReadWriting.Mode getMode()
getMode
in interface ReadWriting
public String getFile()
ReadWriting
getFile
in interface ReadWriting
public void configure(Object... keyValues)
Configuring
Step
. 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 Configuring
public Parameters getParameters()
Parameterizing
getParameters
in interface Parameterizing
public String toString()
toString
in class AbstractStep<ComputerResult,ComputerResult>
public CloneVertexProgram generateProgram(Graph graph, Memory memory)
VertexComputing
VertexProgram
.generateProgram
in interface VertexComputing
graph
- 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()
Step
Step.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.