Functions — github.com/daoqidelv/filespilt-demo

hub / github.com/daoqidelv/filespilt-demo / functions

Functions239 in github.com/daoqidelv/filespilt-demo

⨍ Functions 239◇ Types & classes 34

MethodgetFileContent

()

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:108

MethodgetFileDir

()

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:142

MethodgetFileDir

()

src/main/java/com/daoqidlv/filespilt/Master.java:79

MethodgetFileName

()

src/main/java/com/daoqidlv/filespilt/Master.java:87

MethodgetFileNameTemplate

()

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:158

MethodgetMaxLineSize

()

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:167

MethodgetOrignFileFullName

()

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:143

MethodgetOrignFileFullName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:240

MethodgetOrignFileFullName

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:238

MethodgetQueue

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:189

MethodgetReadSizeOneTime

()

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:273

MethodgetReadSizeOneTime

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:271

MethodgetReadTaskNum

()

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:151

MethodgetSubFileSizeLimit

()

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:150

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask.java:153

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:177

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:167

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:257

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:152

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask.java:159

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:167

MethodgetTaskName

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:255

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask.java:145

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:169

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:159

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:144

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask.java:151

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:159

MethodgetTaskSeq

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:214

MethodgetToReadSize

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:230

MethodgetWriteTaskNum

()

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:159

MethodgetWritenSize

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:185

MethodgetWritenSize

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:175

MethodgetWritenSize

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:160

MethodgetWritenSize

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:175

Methodinit

()

src/test/java/com/daoqidlv/filespilt/mutil/TaskAllocaterTest.java:25

Methodinit

()

src/test/java/com/daoqidlv/filespilt/mutil/FileReadTaskTest.java:32

Methodinit

()

src/main/java/com/daoqidlv/filespilt/mutil/MutilThreadReadMaster.java:53

Methodinit

()

src/main/java/com/daoqidlv/filespilt/disruptor/DisruptorMaster.java:71

MethodisDone

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:193

MethodisDone

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:183

MethodisDone

()

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:168

MethodisDone

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:183

Methodmain

(String[] args)

src/test/java/com/daoqidlv/filespilt/GenBigFile.java:14

Methodmain

参数1：源文件所在目录参数2：原文件名参数3：子文件大小上限值，必须为整数，单位:M 参数4：执行模式：NORMAL -- 使用普通线程池，FORKJOIN -- 使用ForkJoinPool， PRODUCERCONSUMER --生产者-消费者模式；DISRUPTOR -- 生产者-消费者

src/main/java/com/daoqidlv/filespilt/Test.java:19

MethodnewInstance

()

src/main/java/com/daoqidlv/filespilt/disruptor/FileLineEventFactory.java:7

MethodnewThread

(Runnable r)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadThreadFactory.java:10

MethodnewThread

(Runnable r)

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteThreadFactory.java:10

MethodnewThread

(Runnable r)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadThreadFactory.java:10

MethodnewThread

(Runnable r)

src/main/java/com/daoqidlv/filespilt/disruptor/FileLineThreadFactory.java:10

MethodnewThread

(Runnable r)

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteThreadFactory.java:10

MethodonEvent

(FileLine event, long sequence, boolean endOfBatch)

src/main/java/com/daoqidlv/filespilt/disruptor/FileLineEventHandler.java:42

MethodoverFileLimit

检查指定文件大小是否超限 @return true —— 超过 false —— 不超过

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:138

Methodrun

()

src/test/java/com/daoqidlv/filespilt/GenBigFile.java:37

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask.java:62

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:67

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:66

Methodrun

从指定文件目录读取文件内容，并将每行内容转换为FileLine对象，写入queue中。行结束标志：当读取到/n 或者 /r字节时

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:73

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:65

Methodrun

()

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:53

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask.java:62

Methodrun

从queue中读取文件行内容FileLine，写入子文件中，确保子文件大小<10M

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:66

Methodrun

从指定文件目录读取文件内容，并将每行内容转换为FileLine对象，写入queue中。行结束标志：当读取到/n 或者 /r字节时

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:72

MethodsetBeginFilePointer

(int beginFilePointer)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:228

MethodsetBeginFilePointer

(int beginFilePointer)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:226

MethodsetConsumerQueues

(List<BlockingQueue<FileLine>> consumerQueues)

src/main/java/com/daoqidlv/filespilt/disruptor/FileLineEventHandler.java:33

MethodsetDone

(boolean isDone)

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_fos.java:197

MethodsetDone

(boolean isDone)

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeLine_nio.java:187

MethodsetDone

(boolean isDone)

src/main/java/com/daoqidlv/filespilt/mutil/FileWriteTask_writeAll_fos.java:172

MethodsetDone

(boolean isDone)

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:209

MethodsetEndFilePointer

(int endFilePointer)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:269

MethodsetEndFilePointer

(int endFilePointer)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:267

MethodsetFileContent

(List<String> fileContent)

src/main/java/com/daoqidlv/filespilt/single/forkjoin/ForkFileWriteTask.java:112

MethodsetFileContent

(List<String> fileContent)

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:113

MethodsetFileDir

(String fileDir)

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:146

MethodsetFileDir

(String fileDir)

src/main/java/com/daoqidlv/filespilt/Master.java:83

MethodsetFileDir

(String fileDir)

src/main/java/com/daoqidlv/filespilt/single/forkjoin/ForkFileWriteTask.java:92

MethodsetFileDir

(String fileDir)

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:93

MethodsetFileName

(String fileName)

src/main/java/com/daoqidlv/filespilt/Master.java:91

MethodsetFileName

(String fileName)

src/main/java/com/daoqidlv/filespilt/single/forkjoin/ForkFileWriteTask.java:102

MethodsetFileName

(String fileName)

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:103

MethodsetFileNameTemplate

(String fileNameTemplate)

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:162

MethodsetFileSize

(int fileSize)

src/main/java/com/daoqidlv/filespilt/single/forkjoin/ForkFileWriteTask.java:122

MethodsetFileSize

(int fileSize)

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:123

MethodsetFileSpiltter

(FileSpiltter fileSpiltter)

src/main/java/com/daoqidlv/filespilt/Master.java:107

MethodsetFileWritenSize

(int fileWritenSize)

src/main/java/com/daoqidlv/filespilt/single/normal/FileWriteTask.java:133

MethodsetLineContent

(byte[] lineContent)

src/main/java/com/daoqidlv/filespilt/mutil/FileLine.java:38

MethodsetLineSize

(int lineSize)

src/main/java/com/daoqidlv/filespilt/mutil/FileLine.java:30

MethodsetMaxLineSize

(int maxLineSize)

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:171

MethodsetOrignFileFullName

(String orignFileFullName)

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:147

MethodsetOrignFileFullName

(String orignFileFullName)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:244

MethodsetOrignFileFullName

(String orignFileFullName)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:242

MethodsetQueue

(BlockingQueue<FileLine> queue)

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask.java:187

MethodsetQueue

(BlockingQueue<FileLine> queue)

src/main/java/com/daoqidlv/filespilt/disruptor/FileWriteTask_writeLine_nio.java:199

MethodsetReadSizeOneTime

(int readSizeOneTime)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:277

MethodsetReadSizeOneTime

(int readSizeOneTime)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:275

MethodsetReadTaskNum

(int readTaskNum)

src/main/java/com/daoqidlv/filespilt/mutil/TaskAllocater.java:155

MethodsetReadedSize

(int readedSize)

src/main/java/com/daoqidlv/filespilt/mutil/FileReadTask.java:253

MethodsetReadedSize

(int readedSize)

src/main/java/com/daoqidlv/filespilt/disruptor/FileReadTask.java:251

MethodsetSubFileSizeLimit

(int subFileSizeLimit)

src/main/java/com/daoqidlv/filespilt/FileSpiltter.java:154

← previous next →101–200 of 239, ranked by callers