| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/util/ |
| H A D | TestMiniClusterLoadSequential.java | 113 protected MultiThreadedReader prepareReaderThreads(LoadTestDataGenerator dataGen, in prepareReaderThreads() argument
115 MultiThreadedReader reader = new MultiThreadedReader(dataGen, conf, tableName, verifyPercent); in prepareReaderThreads()
119 protected MultiThreadedWriter prepareWriterThreads(LoadTestDataGenerator dataGen, in prepareWriterThreads() argument
121 MultiThreadedWriter writer = new MultiThreadedWriter(dataGen, conf, tableName); in prepareWriterThreads()
167 LoadTestDataGenerator dataGen = new MultiThreadedAction.DefaultDataGenerator(CF); in prepareForLoadTest() local
168 writerThreads = prepareWriterThreads(dataGen, conf, TABLE); in prepareForLoadTest()
169 readerThreads = prepareReaderThreads(dataGen, conf, TABLE, 100); in prepareForLoadTest()
|
| H A D | LoadTestTool.java | 565 LoadTestDataGenerator dataGen = null; in loadTable() local
568 dataGen = getLoadGeneratorInstance(clazzAndArgs[0]); in loadTable()
570 if (dataGen instanceof LoadTestDataGeneratorWithACL) { in loadTable()
597 dataGen.initialize(args); in loadTable()
642 writerThreads = getMultiThreadedWriterInstance(writerClass, dataGen); in loadTable()
658 updaterThreads = getMultiThreadedUpdaterInstance(updaterClass, dataGen); in loadTable()
675 readerThreads = getMultiThreadedReaderInstance(readerClass, dataGen); in loadTable()
752 , LoadTestDataGenerator dataGen) throws IOException { in getMultiThreadedWriterInstance() argument
764 , LoadTestDataGenerator dataGen) throws IOException { in getMultiThreadedUpdaterInstance() argument
770 dataGen, conf, tableName, updatePercent); in getMultiThreadedUpdaterInstance()
[all …]
|
| H A D | RestartMetaTest.java | 81 LoadTestDataGenerator dataGen = new MultiThreadedAction.DefaultDataGenerator( in loadData() local
84 MultiThreadedWriter writer = new MultiThreadedWriter(dataGen, conf, TABLE_NAME); in loadData()
|
| H A D | MultiThreadedWriterBase.java | 75 public MultiThreadedWriterBase(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedWriterBase() argument
77 super(dataGen, conf, tableName, actionLetter); in MultiThreadedWriterBase()
|
| H A D | MultiThreadedWriterWithACL.java | 46 public MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedWriterWithACL() argument
48 super(dataGen, conf, tableName); in MultiThreadedWriterWithACL()
|
| H A D | MultiThreadedReaderWithACL.java | 52 public MultiThreadedReaderWithACL(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedReaderWithACL() argument
54 super(dataGen, conf, tableName, verifyPercent); in MultiThreadedReaderWithACL()
|
| H A D | MultiThreadedWriter.java | 51 public MultiThreadedWriter(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedWriter() argument
53 super(dataGen, conf, tableName, "W"); in MultiThreadedWriter()
|
| H A D | MultiThreadedUpdaterWithACL.java | 62 public MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedUpdaterWithACL() argument
65 super(dataGen, conf, tableName, updatePercent); in MultiThreadedUpdaterWithACL()
|
| H A D | MultiThreadedReader.java | 85 public MultiThreadedReader(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedReader() argument
87 super(dataGen, conf, tableName, "R"); in MultiThreadedReader()
|
| H A D | MultiThreadedUpdater.java | 68 public MultiThreadedUpdater(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedUpdater() argument
70 super(dataGen, conf, tableName, "U"); in MultiThreadedUpdater()
|
| H A D | MultiThreadedAction.java | 151 public MultiThreadedAction(LoadTestDataGenerator dataGen, Configuration conf, in MultiThreadedAction() argument
155 this.dataGenerator = dataGen; in MultiThreadedAction()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/ |
| H A D | IntegrationTestLazyCfLoading.java | 76 private final DataGenerator dataGen = new DataGenerator(); field in IntegrationTestLazyCfLoading
193 for (byte[] cf : dataGen.getColumnFamilies()) { in createTable()
232 new MultiThreadedWriter(dataGen, conf, TABLE_NAME); in testReadersAndWriters()
245 + dataGen.getTotalNumberOfKeys() + " keys"); in testReadersAndWriters()
251 for (byte[] cf : dataGen.getColumnFamilies()) { in testReadersAndWriters()
254 scan.setFilter(dataGen.getScanFilter()); in testReadersAndWriters()
259 long onesGennedBeforeScan = dataGen.getExpectedNumberOfKeys(); in testReadersAndWriters()
272 long onesGennedAfterScan = dataGen.getExpectedNumberOfKeys(); in testReadersAndWriters()
|
| H A D | StripeCompactionsPerformanceEvaluation.java | 71 private LoadTestDataGenerator dataGen; field in StripeCompactionsPerformanceEvaluation
116 dataGen = new MultiThreadedAction.DefaultDataGenerator( in processOptions()
120 dataGen = new SeqShardedDataGenerator(minValueSize, maxValueSize, shards); in processOptions()
203 MultiThreadedWriter preloader = new MultiThreadedWriter(dataGen, conf, TABLE_NAME); in runOneTest()
216 MultiThreadedWriter writer = new MultiThreadedWriter(dataGen, conf, TABLE_NAME); in runOneTest()
217 MultiThreadedReader reader = new MultiThreadedReader(dataGen, conf, TABLE_NAME, 100); in runOneTest()
|
| H A D | IntegrationTestRegionReplicaReplication.java | 122 public DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen, Configuration conf, in DelayingMultiThreadedWriter() argument
124 super(dataGen, conf, tableName); in DelayingMultiThreadedWriter()
141 public DelayingMultiThreadedUpdater(LoadTestDataGenerator dataGen, Configuration conf, in DelayingMultiThreadedUpdater() argument
143 super(dataGen, conf, tableName, updatePercent); in DelayingMultiThreadedUpdater()
|
| /dports/misc/tvm/incubator-tvm-0.6.1/vta/hardware/chisel/src/test/scala/unittest/ |
| H A D | AluTest.scala | 71 val dataGen = new RandomArray(c.blockOut, bits) constant
73 val in_a = dataGen.any
74 val in_b = if (op != 4) dataGen.any else dataGen.negative
|
| /dports/misc/py-tvm/incubator-tvm-0.6.1/vta/hardware/chisel/src/test/scala/unittest/ |
| H A D | AluTest.scala | 71 val dataGen = new RandomArray(c.blockOut, bits) constant
73 val in_a = dataGen.any
74 val in_b = if (op != 4) dataGen.any else dataGen.negative
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/ |
| H A D | PredicateSuite.scala | 149 val dataGen = RandomDataGenerator.forType(t, nullable = true).get constant
151 val value = dataGen.apply()
190 val dataGen = RandomDataGenerator.forType(t, nullable = true).get constant
192 val value = dataGen.apply()
|
| /dports/math/py-Pyomo/Pyomo-6.1.2/pyomo/core/base/ |
| H A D | param.py | 789 dataGen = lambda k, v: [ v._value, ] function
791 dataGen = lambda k, v: [ v, ]
804 dataGen,
|
| /dports/databases/hbase/hbase-1.2.1/hbase-it/src/test/java/org/apache/hadoop/hbase/test/ |
| H A D | IntegrationTestTimeBoundedRequestsWithRegionReplicas.java | 244 public TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen, Configuration conf, in TimeBoundedMultiThreadedReader() argument
246 super(dataGen, conf, tableName, verifyPercent); in TimeBoundedMultiThreadedReader()
|