package edu.uci.ics.hivesterix.runtime.jobgen; | |
import java.util.LinkedList; | |
import java.util.List; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.base.LogicalVariable; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.metadata.IDataSourcePropertiesProvider; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.properties.ILocalStructuralProperty; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.properties.IPartitioningProperty; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.properties.IPhysicalPropertiesVector; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.properties.RandomPartitioningProperty; | |
import edu.uci.ics.hyracks.algebricks.core.algebra.properties.StructuralPropertiesVector; | |
public class HiveDataSourcePartitioningProvider implements | |
IDataSourcePropertiesProvider { | |
@Override | |
public IPhysicalPropertiesVector computePropertiesVector( | |
List<LogicalVariable> scanVariables) { | |
IPartitioningProperty property = new RandomPartitioningProperty( | |
new HiveDomain()); | |
IPhysicalPropertiesVector vector = new StructuralPropertiesVector( | |
property, new LinkedList<ILocalStructuralProperty>()); | |
return vector; | |
} | |
} |