2016-04-08 6 views
1

Ist es möglich, einen benutzerdefinierten Dateisystemadapter für das Status-Back-End zu implementieren?Ist es möglich, einen benutzerdefinierten Dateisystemadapter für das Status-Back-End zu implementieren?

Scheint so, als könnte ich eine eigene Dateisystemadapterbasis auf FileSystem implementieren, aber wie kann ich anfangen, sie in meinem Fluss für das Status-Backend zu verwenden?

+0

Welches Dateisystem möchten Sie mit dem Status-Backend verwenden? –

+0

Ich denke an Riak CS oder Cassandra für Store State. –

+0

Mh. Anscheinend können Sie mit dem S3-Impl von Hadoop auf Riak CS zugreifen. Ich bin mir nicht sicher, Cassandra als FS-Backend zu verwenden. Das staatliche Backend wird Cassandra stark unter Druck setzen. –

Antwort

1

In den meisten Fällen müssen Sie keine benutzerdefinierte Dateisystemimplementierung implementieren, da Flink alle Dateisysteme unterstützt, die von der Hadoop-Schnittstelle FileSystem unterstützt werden.

+0

Sie haben Recht. Ich habe [einen Weg gefunden] (http://stackoverflow.com/a/36646111/2398521), wie man Apache Flink und Riak CS durch Hadoop FileSystem-Schnittstelle beitritt. Vielen Dank! –