Class StagePartitioner

    • Constructor Detail

      • StagePartitioner

        public StagePartitioner()
    • Method Detail

      • addIgnoredPropertyKey

        public void addIgnoredPropertyKey​(Class<? extends VertexExecutionProperty> ignoredPropertyKey)
        By default, the stage partitioner merges two vertices into one stage if and only if the two vertices have same set of VertexExecutionProperty. Invoking this method will make the stage partitioner ignore a specific property during comparing the execution property maps.
        Parameters:
        ignoredPropertyKey - a property that will be ignored during the stage partitioning.
      • getStageProperties

        public Set<VertexExecutionProperty> getStageProperties​(IRVertex vertex)
        Parameters:
        vertex - a vertex in a stage
        Returns:
        set of stage-level properties for the stage