Skip to content

Conversation

@bhanu77prakash
Copy link

As mentioned in the latest issue, I have tried to convert the write mode from line by line to a buffer mode write. I tried running the updated script on the toy dataset and the outputs are exactly same.

def write_triple(f, buffer, ent, rel, t, S, P, O):
"""Write a triple to a file. """
f.write(str(ent[t[S]]) + "\t" + str(rel[t[P]]) + "\t" + str(ent[t[O]]) + "\n")
buffer += f"{str(ent[t[S]])}\t{str(rel[t[P]])}\t{str(ent[t[O]])}\n"
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think it is faster, to make the buffer a list of strings and finally join this list to a single string

buffer_list = []
buffer_list.append(new_triple_string)

buffer = ""
buffer.join(buffer_list)

f.write(str(ent[t[S]]) + "\t" + str(rel[t[P]]) + "\t" + str(ent[t[O]]) + "\n")
buffer += f"{str(ent[t[S]])}\t{str(rel[t[P]])}\t{str(ent[t[O]])}\n"
if len(buffer) > BUFFER_SIZE:
dump_buffer_to_file(buffer, f)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

did you make sure, that the rest of the buffer is written to file at every necessary position? you did so in the RawSplit but process_triple is called also in other splits

@AdrianKs
Copy link
Collaborator

Thanks, this is a good idea. Some small changes are needed though.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants