Skip to content

Commit

Permalink
update documents for Table and WriteBuilder
Browse files Browse the repository at this point in the history
  • Loading branch information
cloud-fan committed May 21, 2019
1 parent d90c460 commit 37343aa
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@
* implementation can be a directory on the file system, a topic of Kafka, or a table in the
* catalog, etc.
* <p>
* This interface can mixin the following interfaces to support different operations, like
* {@code SupportsRead}.
* This interface can mixin {@code SupportsRead} and {@code SupportsWrite} to provide data reading
* and writing ability.
* <p>
* The default implementation of {@link #partitioning()} returns an empty array of partitions, and
* the default implementation of {@link #properties()} returns an empty map. These should be
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,12 @@ default BatchWrite buildForBatch() {
" does not support batch write");
}

/**
* Returns a {@link StreamingWrite} to write data to streaming source. By default this method
* throws exception, data sources must overwrite this method to provide an implementation, if the
* {@link Table} that creates this write returns {@link TableCapability#STREAMING_WRITE} support
* in its {@link Table#capabilities()}.
*/
default StreamingWrite buildForStreaming() {
throw new UnsupportedOperationException(getClass().getName() +
" does not support streaming write");
Expand Down

0 comments on commit 37343aa

Please sign in to comment.