org.apache.flink.streaming.tests

Class DistributedCacheViaBlobTestProgram

java.lang.Object

org.apache.flink.streaming.tests.DistributedCacheViaBlobTestProgram

public class DistributedCacheViaBlobTestProgram
extends Object

End-to-end test program for verifying that files are distributed via BlobServer and later accessible through DistribitutedCache. We verify that via uploading file and later on accessing it in map function. To be sure we read version read from cache, we delete the initial file.

Constructor Summary

Constructors

Constructor and Description
DistributedCacheViaBlobTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DistributedCacheViaBlobTestProgram

public DistributedCacheViaBlobTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception