LTable (Apache Crunch 0.14.0 API)

Type Parameters:

K - key type for this table

V - value type for this table

All Superinterfaces:

LCollection<Pair<K,V>>
```
public interface LTable<K,V>
extends LCollection<Pair<K,V>>
```
Java 8 friendly version of the PTable interface, allowing distributed operations to be expressed in terms of lambda expressions and method references, instead of creating a new class implementation for each operation.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and Description
`default <U> LTable<K,Pair<Collection<V>,Collection<U>>>`	`cogroup(LTable<K,U> other)` Cogroup this table with another `LTable` with the same key type, collecting the set of values from each side.
`default LTable<K,V>`	`filter(SPredicate<Pair<K,V>> predicate)` Filter the rows of the table using the supplied predicate.
`default LTable<K,V>`	`filterByKey(SPredicate<K> predicate)` Filter the rows of the table using the supplied predicate applied to the key part of each record.
`default LTable<K,V>`	`filterByValue(SPredicate<V> predicate)` Filter the rows of the table using the supplied predicate applied to the value part of each record.
`default LGroupedTable<K,V>`	`groupByKey()` Group this table by key to yield a `LGroupedTable`
`default LGroupedTable<K,V>`	`groupByKey(GroupingOptions opts)` Group this table by key to yield a `LGroupedTable`
`default LGroupedTable<K,V>`	`groupByKey(int numReducers)` Group this table by key to yield a `LGroupedTable`
`default LTable<K,V>`	`increment(Enum<?> counter)` Increment a counter for every element in the collection
`default LTable<K,V>`	`increment(String counterGroup, String counterName)` Increment a counter for every element in the collection
`default LTable<K,V>`	`incrementIf(Enum<?> counter, SPredicate<Pair<K,V>> condition)` Increment a counter for every element satisfying the conditional predicate supplied.
`default LTable<K,V>`	`incrementIf(String counterGroup, String counterName, SPredicate<Pair<K,V>> condition)` Increment a counter for every element satisfying the conditional predicate supplied.
`default <U> LTable<K,Pair<V,U>>`	`join(LTable<K,U> other)` Inner join this table to another `LTable` which has the same key type using a reduce-side join
`default <U> LTable<K,Pair<V,U>>`	`join(LTable<K,U> other, JoinType joinType)` Join this table to another `LTable` which has the same key type using the provide `JoinType` and the `DefaultJoinStrategy` (reduce-side join).
`default <U> LTable<K,Pair<V,U>>`	`join(LTable<K,U> other, JoinType joinType, JoinStrategy<K,V,U> joinStrategy)` Join this table to another `LTable` which has the same key type using the provided `JoinType` and `JoinStrategy`
`default LCollection<K>`	`keys()` Get an `LCollection` containing just the keys from this table
`default PType<K>`	`keyType()` Get a `PType` which can be used to serialize the key part of this table
`default <T> LTable<T,V>`	`mapKeys(SFunction<K,T> fn, PType<T> pType)` Transform the keys of this table using the given function
`default <T> LTable<K,T>`	`mapValues(SFunction<V,T> fn, PType<T> pType)` Transform the values of this table using the given function
`default PTableType<K,V>`	`pType()` Get the underlying `PTableType` used to serialize key/value pairs in this table
`PTable<K,V>`	`underlying()` Get the underlying `PTable` for this LCollection
`default LCollection<V>`	`values()` Get an `LCollection` containing just the values from this table
`default PType<V>`	`valueType()` Get a `PType` which can be used to serialize the value part of this table
`default LTable<K,V>`	`write(Target target)` Write this table to the `Target` supplied.
`default LTable<K,V>`	`write(Target target, Target.WriteMode writeMode)` Write this table to the `Target` supplied.

Methods inherited from interface org.apache.crunch.lambda.LCollection
by, cache, cache, count, factory, filterMap, filterMap, flatMap, flatMap, map, map, materialize, parallelDo, parallelDo, parallelDo, parallelDo, ptf, union, union

- Method Detail
 - underlying
```
PTable<K,V> underlying()
```
 Get the underlying PTable for this LCollection
 
 Specified by:
 
 underlying in interface LCollection<Pair<K,V>>
 - groupByKey
```
default LGroupedTable<K,V> groupByKey()
```
 Group this table by key to yield a LGroupedTable
 - groupByKey
```
default LGroupedTable<K,V> groupByKey(int numReducers)
```
 Group this table by key to yield a LGroupedTable
 - groupByKey
```
default LGroupedTable<K,V> groupByKey(GroupingOptions opts)
```
 Group this table by key to yield a LGroupedTable
 - keys
```
default LCollection<K> keys()
```
 Get an LCollection containing just the keys from this table
 - values
```
default LCollection<V> values()
```
 Get an LCollection containing just the values from this table
 - mapKeys
```
default <T> LTable<T,V> mapKeys(SFunction<K,T> fn,
 PType<T> pType)
```
 Transform the keys of this table using the given function
 - mapValues
```
default <T> LTable<K,T> mapValues(SFunction<V,T> fn,
 PType<T> pType)
```
 Transform the values of this table using the given function
 - filter
```
default LTable<K,V> filter(SPredicate<Pair<K,V>> predicate)
```
 Filter the rows of the table using the supplied predicate.
 
 Specified by:
 
 filter in interface LCollection<Pair<K,V>>
 - filterByKey
```
default LTable<K,V> filterByKey(SPredicate<K> predicate)
```
 Filter the rows of the table using the supplied predicate applied to the key part of each record.
 - filterByValue
```
default LTable<K,V> filterByValue(SPredicate<V> predicate)
```
 Filter the rows of the table using the supplied predicate applied to the value part of each record.
 - join
```
default  LTable<K,Pair<V,U>> join(LTable<K,U> other,
 JoinType joinType,
 JoinStrategy<K,V,U> joinStrategy)
```
 Join this table to another LTable which has the same key type using the provided JoinType and JoinStrategy
 - join
```
default  LTable<K,Pair<V,U>> join(LTable<K,U> other,
 JoinType joinType)
```
 Join this table to another LTable which has the same key type using the provide JoinType and the DefaultJoinStrategy (reduce-side join).
 - join
```
default  LTable<K,Pair<V,U>> join(LTable<K,U> other)
```
 Inner join this table to another LTable which has the same key type using a reduce-side join
 - cogroup
```
default  LTable<K,Pair<Collection<V>,Collection>> cogroup(LTable<K,U> other)
```
 Cogroup this table with another LTable with the same key type, collecting the set of values from each side.
 - pType
```
default PTableType<K,V> pType()
```
 Get the underlying PTableType used to serialize key/value pairs in this table
 
 Specified by:
 
 pType in interface LCollection<Pair<K,V>>
 - keyType
```
default PType<K> keyType()
```
 Get a PType which can be used to serialize the key part of this table
 - valueType
```
default PType<V> valueType()
```
 Get a PType which can be used to serialize the value part of this table
 - write
```
default LTable<K,V> write(Target target)
```
 Write this table to the Target supplied.
 
 Specified by:
 
 write in interface LCollection<Pair<K,V>>
 - write
```
default LTable<K,V> write(Target target,
 Target.WriteMode writeMode)
```
 Write this table to the Target supplied.
 
 Specified by:
 
 write in interface LCollection<Pair<K,V>>
 - increment
```
default LTable<K,V> increment(Enum<?> counter)
```
 Increment a counter for every element in the collection
 
 Specified by:
 
 increment in interface LCollection<Pair<K,V>>
 - increment
```
default LTable<K,V> increment(String counterGroup,
 String counterName)
```
 Increment a counter for every element in the collection
 
 Specified by:
 
 increment in interface LCollection<Pair<K,V>>
 - incrementIf
```
default LTable<K,V> incrementIf(Enum<?> counter,
 SPredicate<Pair<K,V>> condition)
```
 Increment a counter for every element satisfying the conditional predicate supplied.
 
 Specified by:
 
 incrementIf in interface LCollection<Pair<K,V>>
 - incrementIf
```
default LTable<K,V> incrementIf(String counterGroup,
 String counterName,
 SPredicate<Pair<K,V>> condition)
```
 Increment a counter for every element satisfying the conditional predicate supplied.
 
 Specified by:
 
 incrementIf in interface LCollection<Pair<K,V>>

Interface LTable<K,V>

Method Summary

Methods inherited from interface org.apache.crunch.lambda.LCollection

Method Detail

underlying

groupByKey

groupByKey

groupByKey

keys

values

mapKeys

mapValues

filter

filterByKey

filterByValue

join

join

join

cogroup

pType

keyType

valueType

write

write

increment

increment

incrementIf

incrementIf