状態バックエンド用のカスタムファイルシステムアダプタを実装することは可能ですか？

私はFileSystemに独自のファイルシステムアダプタベースを実装できますが、それをどのようにして状態のバックエンドのフローで使用することができますか？

どのファイルシステムを状態バックエンドで使用しますか？ –

私は店舗の状態のためにRiak CSまたはCassandraについて考えています。 –

Mh。どうやらHiaopのS3インプットでRiak CSにアクセスできます。私はCassandraをFSのバックエンドとして使用するかどうか分かりません。州のバックエンドは、cassandraに多くのプレッシャーをかけます。 –

ほとんどの場合、FlinkはHadoopのFileSystemインターフェイスでサポートされているすべてのファイルシステムをサポートしているため、カスタムファイルシステム実装を実装する必要はありません。

2016-04-08 11:42:56

あなたは正しいです。私はHadoop FileSystemインターフェースを通してApache FlinkとRiak CSに参加する方法を見つけました（http://stackoverflow.com/a/36646111/2398521）。ありがとうございました！ –

答えて