| Commit message (Collapse) | Author | Age |
|
|
|
|
|
| |
(finite) dataset to a single element.
PiperOrigin-RevId: 214852364
|
|
|
|
| |
PiperOrigin-RevId: 213528716
|
|
|
|
|
|
|
|
| |
state of a function to be executed, separating it out from the non instantiated regular state such as function name, captured inputs etc.
This allows us to truly separate Dataset kernel creation from Iterator creation i.e. each time a dataset is created that uses functions, we create only a CapturedFunction whereas we create an InstantiatedCapturedFunction each time a new iterator is created.
PiperOrigin-RevId: 213456128
|
|
|
|
| |
PiperOrigin-RevId: 211733735
|
|
|
|
| |
PiperOrigin-RevId: 210559796
|
|
|
|
|
|
|
|
|
|
| |
Previously, a function instantiation error (e.g. in `Dataset.map()`) would lead
to an error in each GetNext() call that attempted to use the function. Moving this
to iterator instantiation time has the benefit that the error will be reported
once when the initialization op is executed, which has a more helpful stack
trace, since it should not be conflated with other potential op failures.
PiperOrigin-RevId: 209633511
|
|
|
|
|
|
|
|
|
|
| |
- replacing `OpKernelContext` with newly introduced `DatasetContext` in `DatasetBase` constructor to make it possible to instantiate `DatasetBase` in places where an instance of `OpKernelContext` is not available
- replacing `dataset::MakeIteratorContext(OpKernelContext* ctx)` factory with `IteratorContext(OpKernelContext *ctx)` constructor.
- folding `GraphDatasetBase` into `DataseBase` and removing the default implementation of `AsGraphDefInternal`, making it the responsibility of the derived class to implement it to encourage/hint developers to provide serialization logic
PiperOrigin-RevId: 208560010
|
|
|
|
|
|
|
|
| |
This CL:
- changes the `OptimizeDataset` checkpointing logic to checkpoint the optimized dataset (as opposed to the original dataset + the optimizations, re-running optimization every time a checkpoint is restored)
- replaces `OpKernelContext` with newly introduced `SerializationContext` in the signature of `AsGraphDefInternal` to reduce the scope of the context and also simplify the logic for overriding the `FunctionLibraryDefinition` when optimizations take place
PiperOrigin-RevId: 208282562
|
|
|
|
|
|
| |
Renaming `AddParentDataset`, `SaveParent`, and `RestoreParent` to `AddInputDataset`, `SaveInput`, and `RestoreInput`.
PiperOrigin-RevId: 208272695
|
|
|
|
|
|
|
|
| |
This change introduces the `window` tf.data transformation, which can be used to create windows of elements (represented as a dataset) from a dataset. This transformation enables applying different batching logic to different components of a dataset.
To illustrate the benefits of the transformation, this CL also introduces transformations for batching and padded batching of windows of both dense and sparse tensors. Notably, padded batching of sparse tensors was previously not possible.
PiperOrigin-RevId: 203179522
|
|
|
|
|
|
| |
By marking DebugString() as const we can make some error messages more descriptive. Because DatasetIterator marks the return value of the dataset() function const, DebugString() cannot be called.
PiperOrigin-RevId: 198796894
|
|
|
|
|
|
| |
status.
PiperOrigin-RevId: 198772254
|
|
groups elements of an input pipeline by a key, applies a reduce function to elements of each group "on-the-fly", and outputs the results once all input elements have been processed.
PiperOrigin-RevId: 194874087
|