apache storm-使用hdfsbolt将文件移动到其他位置不起作用

xzabzqsa  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(171)

我有下面的代码,我试图移动文件到一个不同的位置,一旦文件旋转完成。movefileaction没有发生(也没有错误)。我不确定我是否遗漏了什么。

SyncPolicy syncPolicy = new CountSyncPolicy(100);

// Rotate data files when they reach five MB
FileRotationPolicy rotationPolicy = new FileSizeRotationPolicy(0.05f, Units.MB);

MoveFileAction moveFileAction = new MoveFileAction().toDestination(rootPath + "/test");

FileNameFormat fileNameFormat = new DefaultFileNameFormat()
                    .withPath(rootPath + "/staging")
                    .withPrefix(prefix);

// Instantiate the HdfsBolt
HdfsBolt hdfsBolt = new HdfsBolt()
             .withFsUrl(fsUrl)
             .withFileNameFormat(fileNameFormat)
             .withRecordFormat(format)
             .withRotationPolicy(rotationPolicy)
             .withSyncPolicy(syncPolicy)
             .addRotationAction(moveFileAction);

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题