Examples of PartitionKey

com.bazaarvoice.ostrich.partition.PartitionKey
com.cloudera.cdk.data.PartitionKey

A key for retrieving partitions from a {@link Dataset}.

A {@code PartitionKey} is a ordered sequence of values corresponding to the{@link FieldPartitioner}s in a {@link PartitionStrategy}. A {@link PartitionKey} may be obtained using{@link PartitionStrategy#partitionKey(Object)} or{@link PartitionStrategy#partitionKeyForEntity(Object)}.

Implementations of {@link PartitionKey} are typically not thread-safe; that is,the behavior when accessing a single instance from multiple threads is undefined.
@see PartitionStrategy @see FieldPartitioner @see Dataset
com.facebook.presto.spi.PartitionKey
com.mysql.clusterj.core.store.PartitionKey
This interface represents a partition key. A partition key consists of a table and values that make up the partition key. An instance of this interface can be used to specify the partition key used when starting a transaction.
org.kitesdk.data.spi.PartitionKey

A key for retrieving partitions from a {@link org.kitesdk.data.Dataset}.

A {@code PartitionKey} is an ordered sequence of values corresponding to the{@link org.kitesdk.data.spi.FieldPartitioner}s in a {@link org.kitesdk.data.PartitionStrategy}. You can obtain a {@link PartitionKey} using{@link PartitionKey#partitionKeyForEntity(org.kitesdk.data.PartitionStrategy,Object,EntityAccessor,PartitionKey)}.

Implementations of {@link PartitionKey} are typically not thread-safe; that is, the behavior when accessing a single instance from multiple threads is undefined.
@see org.kitesdk.data.PartitionStrategy @see org.kitesdk.data.spi.FieldPartitioner @see org.kitesdk.data.Dataset

Examples of org.kitesdk.data.spi.PartitionKey

      throw new DatasetIOException("Unable to list partition directory for directory " + directory, e);
    }


    for (FileStatus stat : fileStatuses) {
      Path p = fileSystem.makeQualified(stat.getPath());
      PartitionKey key = keyFromDirectory(p.getName());
      PartitionStrategy subPartitionStrategy = Accessor.getDefault()
          .getSubpartitionStrategy(partitionStrategy, 1);
      Builder<E> builder = new FileSystemDataset.Builder<E>()
          .namespace(namespace)
          .name(name)

View Full Code Here

Examples of org.kitesdk.data.spi.PartitionKey

      values.addAll(partitionKey.getValues());
    }


    values.add(convert.valueForDirname(fp, name));


    return new PartitionKey(values.toArray());
  }

View Full Code Here

Examples of org.kitesdk.data.spi.PartitionKey


    if (partitionKey != null) {
      values.addAll(0, partitionKey.getValues());
    }


    return new PartitionKey(values.toArray());
  }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.